package service; 

import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
/** 
* @author 朱宏亮
* @version 创建时间：2017年12月4日 下午4:56:13 
* 类说明 
*/

@Service
public class ConsumerService {

    @Resource(name="jmsTemplate")
    private JmsTemplate jmsTemplate;
     
    /**
     * 接收消息
     */
    public TextMessage receive(Destination destination) {
        TextMessage tm = (TextMessage) jmsTemplate.receive(destination);
        try {
           
            System.out.println("\n从队列" + destination.toString() + "收到了消息：\t" + tm.getText()+"\n");
     
        } catch (JMSException e) {
            //e.printStackTrace();
            System.out.println("\n暂无消息\n");
        }
       
        
        return tm;
        
    }
 
}
 